package cn.zhage.aimin.canal.client.client;

import com.alibaba.otter.canal.client.CanalConnector;

/*
 * 
 * @author 渣哥
*/
public interface CanalClient {

    CanalConnector createConnector();
    void connect();
    void receive();
    void disconnect();
}
